from sqlalchemy.ext.asyncio import AsyncSession
from sqlalchemy import select
from app.models import Activity, NetworkVolumeObservation


async def collect_news(session: AsyncSession, activity_id: str) -> int:
    act = await session.get(Activity, activity_id)
    if not act:
        return 0
    return 0
